package org.example;

import org.example.client.RpcInvoker;
import org.example.service.RpcService;

/**
 * Hello world!
 */
public class ConsumerBoot {
    public static void main(String[] args) throws InterruptedException {
        RpcInvoker rpcInvoker = new RpcInvoker();
        RpcService proxy = (RpcService) rpcInvoker.createProxy(RpcService.class);

        while (true){
            proxy.print("World!");
            proxy.count(6);
            Thread.sleep(2000);
        }
    }
}
